package cn.com.wangluotongxin.netty.rabbitmq;

import cn.com.wangluotongxin.admin.netty.AdminQueue;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitmqConfig {

    @Bean
    public Queue localAdminNettySendMessageQueue() {
        return new Queue(AdminQueue.ADMIN_NETTY_MESSAGE_PUSH, true);
    }

    @Bean
    public Queue localAdminNettyNotifyResponseQueue() {
        return new Queue(AdminQueue.ADMIN_NETTY_NOTIFY_RESPONSE, true);
    }

    @Bean
    public Queue localAdminAiSearchPushQueue() {
        return new Queue(AdminQueue.ADMIN_NETTY_AI_SEARCH_PUSH, true);
    }

    @Bean
    public Queue localAdminFriendInputStatusPushQueue() {
        return new Queue(AdminQueue.ADMIN_FRIEND_INPUT_STATUS_PUSH, true);
    }
}
